35da6a50868b33cca0bbcaf351e5770f6d821ab4,src/test/java/com/continuuity/runtime/FlowTest.java,FlowTest,testCountRandomApp,#,163

Before Change



  @Test
  public void testCountRandomApp() throws Exception {
    final CConfiguration configuration = CConfiguration.create();
    configuration.set(Constants.CFG_APP_FABRIC_TEMP_DIR, System.getProperty("java.io.tmpdir") + "/app/temp");
    configuration.set(Constants.CFG_APP_FABRIC_OUTPUT_DIR, System.getProperty("java.io.tmpdir")
                                                            + "/app/archive" + UUID.randomUUID());

    Injector injector = Guice.createInjector(new DataFabricModules().getInMemoryModules(),
                                             new BigMamaModule(configuration));

    LocalLocationFactory lf = new LocalLocationFactory();

    Location deployedJar = lf.create(
      JarFinder.getJar(TestCountRandomApp.class, TestHelper.getManifestWithMainClass(TestCountRandomApp.class))
    );
    deployedJar.deleteOnExit();

    ListenableFuture<?> p = TestHelper.getLocalManager(configuration).deploy(DefaultId.ACCOUNT, deployedJar);
    final ApplicationWithPrograms app = (ApplicationWithPrograms)p.get();
    ProgramController controller = null;
    for (final Program program : app.getPrograms()) {
      if (program.getProcessorType() == Type.FLOW) {

After Change



  @Test
  public void testCountRandomApp() throws Exception {
    TestHelper.getInjector().getInstance(DiscoveryService.class).startAndWait();
    final ApplicationWithPrograms app = TestHelper.deployApplicationWithManager(TestCountRandomApp.class);
    ProgramController controller = null;
    for (final Program program : app.getPrograms()) {
      if (program.getProcessorType() == Type.FLOW) {
        ProgramRunner runner = TestHelper.getInjector().getInstance(FlowProgramRunner.class);
        controller = runner.run(program, new ProgramOptions() {
          @Override
          public String getName() {